package com.ruoyi.smart.mqtt;

import org.eclipse.paho.client.mqttv3.MqttMessage;

/**
 * MQTT消息处理器接口
 * 所有特定主题的消息处理器都应实现此接口
 */
public interface MessageHandler {

    /**
     * 获取该处理器能处理的主题过滤器
     * 支持通配符，如: "sch/+/data", "device/+/status"
     * @return 主题过滤器
     */
    String getTopicFilter();

    /**
     * 处理收到的MQTT消息
     * @param topic 消息实际到达的主题
     * @param message MQTT消息对象
     */
    void handleMessage(String topic, MqttMessage message);
}
